package cn.stacey.jd.es;

import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;

import cn.stacey.jd.dao.ProductIndexDao;
import cn.stacey.jd.domain.Product;


@RunWith(SpringRunner.class)
@ContextConfiguration("classpath:context.xml")
public class testIndex {
	@Autowired
	ProductIndexDao dao;
	
	@Autowired
	ElasticsearchTemplate template;
	
//	@Autowired
//	ProductMapper mapper;
	
	
	@Test
	public void testDelete() {
		template.deleteIndex("product");
	}
	
	@Test
	public void testIndexOps() {
		template.createIndex(Product.class);
	}
	
	@Test
	public void addMapping() {
		template.putMapping(Product.class);
	}
		
//	@Test
//	public void test2() {
//		List<Product> list = mapper.findAll(0, 10);
//		list.forEach(p ->{
//			System.out.println(p.getId());
//		});
//		
//	}
//	
//	@Test
//	public void testImportData() {
//		long start = System.currentTimeMillis();
//		final int PAGE_SIZE = 100;
//		int total=mapper.getCount();
//		for(int i=0;i<total;i+=PAGE_SIZE) {
//			System.out.println("正在导入第"+i+"到"+(i+PAGE_SIZE)+"条");		
//	//用mybatis的Mapper接口读取数据
//		List<Product> list = mapper.findAll(i, PAGE_SIZE);
//		list.forEach(p ->{
//			System.out.println(p.getId());
//		});
//		//使用elasticsearch接口写索引库
//		dao.saveAll(list);
//		}
//		long end = System.currentTimeMillis();
//		System.out.println("耗时："+(end-start)/1000);
//	}
}
